package drds.global_transaction.api.rpc.rpc_server;

import drds.global_transaction.api.message_codec.request_and_response.register_manager.resource_manager.RegisterResourceManagerRequestMessage;
import drds.global_transaction.api.message_codec.request_and_response.register_manager.transaction_manager.RegisterTransactionManagerRequestMessage;
import io.netty.channel.ChannelHandlerContext;

public interface TransactionMessageListener
{

	void onPing(ChannelHandlerContext channelHandlerContext, MessageSend messageSend, long messageId);

	void onRegisterTransactionManagerRequest(ChannelHandlerContext channelHandlerContext, MessageSend messageSend, long messageId, RegisterTransactionManagerRequestMessage registerTransactionManagerRequest, RegisterCheckAuthHandler registerCheckAuthHandler);

	void onRegisterResourceManagerRequest(ChannelHandlerContext channelHandlerContext, MessageSend messageSend, long messageId, RegisterResourceManagerRequestMessage registerResourceManagerRequest, RegisterCheckAuthHandler registerCheckAuthHandler);

	void onMessage(ChannelHandlerContext channelHandlerContext, MessageSend messageSend, long messageId, Object message);

}
